/*
 * Copyright 1999-2018 Alibaba Group Holding Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.alibaba.csp.sentinel.dashboard.rule.nacos;

import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.ApiDefinitionEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.gateway.GatewayFlowRuleEntity;
import com.alibaba.csp.sentinel.dashboard.datasource.entity.rule.*;
import com.alibaba.csp.sentinel.datasource.Converter;
import com.alibaba.fastjson.JSON;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigFactory;
import com.alibaba.nacos.api.config.ConfigService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.List;
import java.util.Properties;

/**
 * @author Eric Zhao
 * @since 1.4.0
 */
@Configuration
public class NacosConfig {

	// =================================================流控规则
	// Converter================================================
	@Bean
	public Converter<List<FlowRuleEntity>, String> flowRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<FlowRuleEntity>> flowRuleEntityDecoder() {
		return s -> JSON.parseArray(s, FlowRuleEntity.class);
	}

	// =================================================降级规则
	// Converter================================================
	@Bean
	public Converter<List<DegradeRuleEntity>, String> degradeRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<DegradeRuleEntity>> degradeRuleEntityDecoder() {
		return s -> JSON.parseArray(s, DegradeRuleEntity.class);
	}

	// ================================================热点规则
	// Converter=================================================
	@Bean
	public Converter<List<ParamFlowRuleEntity>, String> paramsRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<ParamFlowRuleEntity>> paramsRuleEntityDecoder() {
		return s -> JSON.parseArray(s, ParamFlowRuleEntity.class);
	}

	// ================================================系统规则
	// Converter=================================================
	@Bean
	public Converter<List<SystemRuleEntity>, String> systemRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<SystemRuleEntity>> systemRuleEntityDecoder() {
		return s -> JSON.parseArray(s, SystemRuleEntity.class);
	}

	// ==============================================授权规则
	// Converter===================================================
	@Bean
	public Converter<List<AuthorityRuleEntity>, String> authRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	Converter<String, List<AuthorityRuleEntity>> authRuleEntityDecoder() {
		return s -> JSON.parseArray(s, AuthorityRuleEntity.class);
	}

	// ==============================================网关API限流规则
	// Converter=============================================
	@Bean
	public Converter<List<ApiDefinitionEntity>, String> apiDefinitionEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<ApiDefinitionEntity>> apiDefinitionEntityDecoder() {
		return s -> JSON.parseArray(s, ApiDefinitionEntity.class);
	}

	// ===============================================网关限流规则
	// Converter==============================================
	@Bean
	public Converter<List<GatewayFlowRuleEntity>, String> gatewayFlowRuleEntityEncoder() {
		return JSON::toJSONString;
	}

	@Bean
	public Converter<String, List<GatewayFlowRuleEntity>> gatewayFlowRuleEntityDecoder() {
		return s -> JSON.parseArray(s, GatewayFlowRuleEntity.class);
	}

	@Bean
	public ConfigService nacosConfigService(SentinelNacosProperties sentinelNacosProperties) throws Exception {
		Properties config = new Properties();
		// nacos 地址
		config.put(PropertyKeyConst.SERVER_ADDR, sentinelNacosProperties.getServerAddr());
		// nacos 名称空间
		config.put(PropertyKeyConst.NAMESPACE, sentinelNacosProperties.getNamespace());
		// nacos 账号
		config.put(PropertyKeyConst.USERNAME, sentinelNacosProperties.getUsername());
		// nacos 账号密码
		config.put(PropertyKeyConst.PASSWORD, sentinelNacosProperties.getPassword());

		return ConfigFactory.createConfigService(config);
	}

}
